package com.hmc.kafka.withFlink;

import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;

public class FlinkKafkaProducer1 {
    public static void main(String[] args) {
        //获取环境
        StreamExecutionEnvironment environment = StreamExecutionEnvironment.getExecutionEnvironment();

        //准备数据源

        //添加数据源

        //执行代码
    }
}
